//package com.ytjj.qmyx.mall.kafka;
//
//import org.springframework.cloud.stream.annotation.Output;
//import org.springframework.messaging.MessageChannel;
//
//public interface IOrderRecordKafkaOut {
//    String ORDER_RECORD_KAFKA_OUT="output-orderrecord";
//    String  ORDER_RECORD_HISTORY_OUT = "orderrecord";//发送历史数据topic
//    String ORDER_RECORD_NEW_OUT="output-orderrecordnew";
//
//    String ORDER_RECORD_HISTORY_OUT_DELETE = "output-orderrecord_tmp";
//
//    @Output(ORDER_RECORD_KAFKA_OUT)
//    MessageChannel output();
//
//    @Output(ORDER_RECORD_HISTORY_OUT)
//    MessageChannel historyOutput();
//
//    @Output(ORDER_RECORD_NEW_OUT)
//    MessageChannel newOutput();
//
//    @Output(ORDER_RECORD_HISTORY_OUT_DELETE)
//    MessageChannel orderRecordHistoryOutput();
//}
